package com.imooc.flink.cdc;

import com.ververica.cdc.debezium.DebeziumSourceFunction;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;

/**
 * @author: Chen Yixing
 * @since: 2023/10/31 19:43:00
 * @description:
 */
public class MysqlCdc {
    private final static String TAG = "MysqlCdc";

    public static void main(String[] args) throws Exception {
        StreamExecutionEnvironment environment = StreamExecutionEnvironment.getExecutionEnvironment();

        DebeziumSourceFunction source = CdcSource.getSource();

        environment.addSource(source).print();

        environment.execute(TAG);
    }
}
